home *** CD-ROM | disk | FTP | other *** search
/ Meeting Pearls 2 / Meeting Pearls Vol. II (1995)(GTI - Schatztruhe)[!].iso / Pearls / arc / XFH / src / xobj.c < prev    next >
C/C++ Source or Header  |  1994-04-17  |  13KB  |  478 lines
  1. /* xobj.c - 'wrapper' calls for directing requests through to
  2.    the underlying file system. 
  3.    Copyright (C) 1991, 1992, 1993 Kristian Nielsen.
  4.  
  5.    This file is part of XFH, the compressing file system handler.
  6.  
  7.    This program is free software; you can redistribute it and/or modify
  8.    it under the terms of the GNU General Public License as published by
  9.    the Free Software Foundation; either version 2 of the License, or
  10.    (at your option) any later version.
  11.  
  12.    This program is distributed in the hope that it will be useful,
  13.    but WITHOUT ANY WARRANTY; without even the implied warranty of
  14.    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  15.    GNU General Public License for more details.
  16.  
  17.    You should have received a copy of the GNU General Public License
  18.    along with this program; if not, write to the Free Software
  19.    Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.            */
  20.  
  21. #include "CFS.h"
  22.  
  23. #include <dossupport.h>
  24.  
  25. LONG XObjClose(glb glob,struct CFSFH *fh)
  26.  
  27. {
  28.  LONG Result;
  29.   
  30.  if (!(Result=xClose(glob, fh->xfh)))
  31.   return Result;  /* Dare not free the file handle. */
  32.  
  33.  fh->xfh=NULL;
  34.   
  35.  /* Check whether we need to compress the file (signified by a non-NULL
  36.   * fh->filename field). */
  37.  
  38.  if (fh->filename)
  39.   {
  40.    debug (("Attempting to compress file '%s'...",fh->filename));
  41. #ifdef DEBUG
  42.    Result=TransformFile(glob,fh->parent->xlock,fh->filename,PackFile2File,NULL);
  43.    debug (("result: %ld (ioerr=%ld).\n",Result,glob->ioerr));
  44. #else
  45.    (void)TransformFile(glob,fh->parent->xlock,fh->filename,PackFile2File,NULL);
  46. #endif
  47.  
  48.    /* Even if the compressing fails, we still have the file intact. */
  49.  
  50.    /* create xScan filenote if possible */
  51.    xScan (glob,fh->parent->xlock,fh->filename);
  52.   }
  53.  
  54.  XObjFreeFH (glob,fh);
  55.  return DOSTRUE;
  56. }
  57.  
  58.  
  59. LONG XObjRead( glb glob, struct CFSFH *fh, UBYTE *buf, LONG len ){
  60.    return xRead( glob, fh->xfh, buf, len );
  61. }
  62.  
  63.  
  64. LONG XObjWrite( glb glob, struct CFSFH *fh, UBYTE *buf, LONG len ){
  65.    return xWrite( glob, fh->xfh, buf, len );
  66. }
  67.  
  68.  
  69. LONG XObjSeek( glb glob, struct CFSFH *fh, LONG pos, LONG offset ){
  70.    return xSeek( glob, fh->xfh, pos, offset );
  71. }
  72.  
  73.  
  74. /* Allocate and partly initialise a struct CFSFH (should ONLY be called
  75.  * from XObjCreateFH()!).
  76.  */
  77. static struct CFSFH *XObjAllocFH(glb glob, struct FileHandle *xfh, LONG mode){
  78.    struct CFSFH *newfh;
  79.  
  80.    if( !dalloc(newfh) ){
  81.       debug(("Error: XObjAllocFH(): No memory for file handle.\n"));
  82.       OUTOFMEM;
  83.       return NULL;
  84.    }
  85.  
  86.    newfh->objtype = XOBJECT;
  87.    newfh->mode = mode;
  88.    newfh->xfh = xfh;
  89.    newfh->f = &Xfunc;
  90.    /* Other fields are NULL by default. */
  91.    return newfh;
  92. }
  93.  
  94.  
  95. /* This function is needed to convert from XpkFH to CFSFH in Xpk_Write(). */
  96. void XObjStealXpkFH(glb glob, struct CFSFH *fh){
  97.   fh->objtype = XOBJECT;
  98.   fh->f = &Xfunc;
  99. }  
  100.  
  101.  
  102. /* Stuff the filename / parentdir thingies into a CFSFH file handle. Must
  103.  * be 'undone' with XObjUnStuffFH().
  104.  */
  105. BOOL XObjStuffFH(glb glob, struct CFSFH *fh, char *name,
  106.          struct CFSLock *parent){
  107.  
  108.   debug(("Setting up fields in fh for autocompressing at Close().\n"));
  109.   if(!(fh->filename = copystr(name))){
  110.     debug(("Error: XObjStuffFH(): No memory for file name.\n"));
  111.     OUTOFMEM;
  112.     return FALSE;
  113.   }
  114.   if(!(fh->parent = CFSDupLock(glob, parent))){
  115.     /* Couldn't DupLock() it, so just hold a reference. */
  116.     debug(("XObjStuffFH(): Couldn't DupLock() parent, adding reference.\n"));
  117.     XObjAddReferenceToLock(glob, parent);
  118.     fh->parent = parent;
  119.     /* NOTE: We now have a dangerous double reference to the
  120.      * lock. Notably, the lock will be CFSUnLock()'ed two
  121.      * times.
  122.      */
  123.   }
  124.   return TRUE;
  125. }
  126.  
  127.  
  128. void XObjUnStuffFH(glb glob, struct CFSFH *fh){
  129.   if(fh->filename){
  130.     freestr(fh->filename);
  131.     CFSUnLock(glob, fh->parent);
  132.     fh->filename = NULL;
  133.     fh->parent = NULL;
  134.   }
  135. }
  136.   
  137.  
  138. /* Free CFSFH allocated with XObjCreateFH() (will not close the file handle).*/
  139. void XObjFreeFH(glb glob, struct CFSFH *fh){
  140.   XObjUnStuffFH(glob, fh);
  141.   dfree(fh);
  142. }
  143.  
  144.  
  145. /* Create a file handle to an xObj file. If 'name' is non-NULL,
  146.  * and autocompression is ON, will prepare filehandle for autocompression
  147.  * at Close() time (assuming 'parent' to be a lock on the parentdir of
  148.  * the file).
  149.  */
  150. struct CFSFH *XObjCreateFH(glb glob, struct FileHandle *xfh, LONG mode,
  151.                                  char *name,struct CFSLock *parent){
  152.   struct CFSFH *newfh;
  153.  
  154.   if( !( newfh = XObjAllocFH(glob, xfh, mode) ) ){
  155.     return NULL;
  156.   }
  157.  
  158.   /* Prepare for compressing the file at Close() time if needed. */
  159.   if(glob->autocompress && name){
  160.     if(!XObjStuffFH(glob, newfh, name, parent)){
  161.       SAVEIOERR;
  162.       XObjFreeFH(glob, newfh);
  163.       RESTIOERR;
  164.       return NULL;
  165.     }
  166.   }
  167.   return newfh;
  168. }
  169.  
  170.  
  171. /* Wraps a CFSLock around an xLock. */
  172. struct CFSLock *XObjMakeLock( glb glob, struct FileLock *xlock, LONG mode ){
  173.    struct CFSLock *newlock;
  174.  
  175.    if( !dalloc(newlock) ){
  176.       OUTOFMEM;
  177.       return NULL;
  178.    }
  179. debug(("XObjMakeLock(): xlock=%lx, procid=%lx.\n",xlock,xlock->fl_Task));
  180.    newlock->objtype = XOBJECT;
  181.    newlock->mode = mode;
  182.    newlock->xlock = xlock;
  183.    newlock->f = &Xfunc;
  184.    newlock->refcount = 0;
  185.    return newlock;
  186. }
  187.  
  188. struct CFSLock *XObjDupLock( glb glob, struct CFSLock *lock ){
  189.    struct CFSLock *newlock;
  190.  
  191.    /* XOBJECT locks have their xLocks xDupLock'ed, and the rest of
  192.     * the fields are just copied vanilla.
  193.     * Special case for the refcount; it must be set to 0 in the new lock.
  194.     */
  195.    if( !dalloc(newlock) ){
  196.       OUTOFMEM;
  197.       return 0L;
  198.    }
  199.    *newlock = *lock;
  200.    newlock->refcount = 0;   /* IMPORTANT!!! */
  201.    if( !(newlock->xlock = xDupLock(glob, lock->xlock)) ){
  202.       dfree(newlock);
  203.       return 0L;
  204.    }
  205.    return newlock;   
  206. }
  207.  
  208. /* This nasty function adds a reference to a CFSLock. FOR EACH CALL TO
  209.  * THIS FUNCTION THERE MUST BE A CORRESPONDING CALL TO XObjUnLock(), as
  210.  * well as a final one to match the original XObjLock(), XObjDupLock() or
  211.  * whatever.
  212.  */
  213. void XObjAddReferenceToLock(glb glob, struct CFSLock *lock){
  214.    lock->refcount++;
  215. }
  216.  
  217.  
  218. struct CFSLock *XObjParentDir( glb glob, struct CFSLock *lock ){
  219.     struct FileLock *xlock;
  220.     struct CFSLock *newlock;
  221.     
  222.     if( xSameLock(glob, glob->xrootlock, lock->xlock) == LOCK_SAME ){
  223.         debug(("- ParentDir() of root lock. -"));
  224.         glob->ioerr = 0L;
  225.         return NULL;
  226.     }
  227.     if( !(xlock = xParentDir(glob, lock->xlock)) ){
  228.         return 0L;
  229.     }
  230.     newlock = XObjMakeLock( glob, xlock, ACCESS_READ );
  231.     if( !newlock ){
  232.         LONG saveioerr = glob->ioerr;
  233.         xUnLock(glob, xlock);
  234.         glob->ioerr = saveioerr;
  235.     }
  236.     return newlock;
  237. }
  238.  
  239.  
  240. struct CFSLock *XObjParentFH( glb glob,  struct CFSFH *fh ){
  241.     struct FileLock *xlock;
  242.     struct CFSLock *newlock;
  243.     
  244.     if( !(xlock = xParentFH(glob, fh->xfh)) ){
  245.         return 0L;
  246.     }
  247.     newlock = XObjMakeLock( glob, xlock, ACCESS_READ );
  248.     if( !newlock ){
  249.         LONG saveioerr = glob->ioerr;
  250.         xUnLock(glob, xlock);
  251.         glob->ioerr = saveioerr;
  252.     }
  253.     return newlock;
  254. }
  255.  
  256.  
  257. BOOL XObjUnLock( glb glob, struct CFSLock *lock ){
  258.     BOOL err;
  259.  
  260.    /* Have to check if there are outstanding references to the lock. */
  261.    if(lock->refcount){
  262.       debug(("XObjUnLock: Just decrementing the refcount (%ld).\n",lock->refcount));
  263.       lock->refcount--;
  264.       return DOSTRUE;
  265.    }
  266.    
  267.     err = xUnLock(glob, lock->xlock);
  268.       
  269.     /* Now, what if the UnLock fails? I guess it's best to return FALSE
  270.      * and let the lock live.
  271.      */
  272.     if(!err) return DOSFALSE;
  273.     dfree(lock);
  274.     return DOSTRUE;
  275. }
  276.  
  277.  
  278. BOOL XObjSameLock(glb glob, struct CFSLock *l1, struct CFSLock *l2 ){
  279.     return (BOOL) (xSameLock( glob, l1->xlock, l2->xlock ) == LOCK_SAME);
  280. }
  281.  
  282. BOOL XObjMakeLink(glb glob,struct CFSLock *ParentLock,char *Name,
  283.                   LONG Dest,LONG Type)
  284.  
  285. {
  286.  if (Type)
  287.   {
  288.    debug (("XObjMakeLink: LINK_SOFT\n"));
  289.    return xMakeLink(glob,ParentLock->xlock,Name,Dest,LINK_SOFT);
  290.   }
  291.  else
  292.   {
  293.    struct FileLock *DestLock;
  294.  
  295.    debug (("XObjMakeLink: LINK_HARD\n"));
  296.  
  297.    DestLock=(struct FileLock *)b2c(Dest);
  298.    if (DestLock->fl_Task!=glob->dosport)
  299.     {
  300.      debug (("Error: not our lock !\n"));
  301.      glob->ioerr=ERROR_OBJECT_WRONG_TYPE;
  302.      return DOSFALSE;
  303.     }
  304.    DestLock=((struct CFSLock *)DestLock->fl_Key)->xlock;
  305.    return xMakeLink(glob,ParentLock->xlock,Name,c2b(DestLock),LINK_HARD);
  306.   }
  307. }
  308.  
  309. BOOL XObjReadLink(glb glob,struct CFSLock *ParentLock,char *Name,
  310.                   char *Buffer,ULONG Size)
  311.  
  312. {
  313.  return xReadLink(glob,ParentLock->xlock,Name,Buffer,Size);
  314. }
  315.  
  316. BOOL XObjExamine( glb glob, struct CFSLock *lock, struct FileInfoBlock *fib ){
  317.    BOOL err, fix=FALSE;
  318.    
  319.    if(xSameLock(glob, glob->xrootlock, lock->xlock) == LOCK_SAME) fix=TRUE;
  320.    err = xExamine(glob, lock->xlock, fib);
  321.    debug(("XObjExamine(): %ld,'%s'\n",err,fib->fib_FileName));
  322.  
  323.    (void)XpkFastModifyFIB(fib);
  324.    
  325.    /* Check if Examine()'ing the root dir (if so, fix name). */
  326.    if(fix){
  327.       /* ARRGHH! Nasty BCPL stuff around... */
  328.       bstr2c(glob->volnode->dl_Name, &fib->fib_FileName[0]);
  329.       debug(("XObjExamine(): Changing name in FIB to '%s'.\n",
  330.                                                  &fib->fib_FileName[0]));
  331.    }
  332.    return err;
  333. }
  334.  
  335. BOOL XObjExNext( glb glob, struct CFSLock *lock, struct FileInfoBlock *fib ){
  336.    BOOL err, err2;
  337.    
  338.    err = xExamineNext(glob, lock->xlock, fib);
  339.    debug(("CFSExamineNext(): %ld,'%s'\n",err,fib->fib_FileName));
  340.    if( !err ) return err;
  341.    err2 = ModifyFIB( glob, lock, fib );
  342.    if(!glob->FailOnExNext){
  343.       /* The error return from ModifyFIB is discarded. This way, a directory
  344.        * scan won't fail in flaky programs that don't test IOERR for
  345.        * ERROR_NO_MORE_ENTRIES.
  346.        */
  347.    }else{
  348.       err = err2;
  349.    }
  350.    return err;
  351. }
  352.  
  353.  
  354. BOOL XObjExamineFH( glb glob, struct CFSFH *fh, struct FileInfoBlock *fib ){
  355.    BOOL err;
  356.  
  357.    err = xExamineFH(glob, fh->xfh, fib);
  358.    debug(("XObjExamineFH(): %ld,'%s'\n",err,fib->fib_FileName));
  359.  
  360.    (void)XpkFastModifyFIB(fib);
  361.  
  362.    return err;
  363. }
  364.  
  365. BOOL ModifyFIB( glb glob, struct CFSLock *lock, struct FileInfoBlock *fib ){
  366.    LONG saveioerr;
  367.    
  368.    if( fib->fib_DirEntryType < 0 ){
  369.       LONG filetype;
  370.       struct FileHandle *xfh;
  371.       BOOL err;
  372.  
  373.       if ( XpkFastModifyFIB(fib) ) return DOSTRUE;
  374.  
  375.       /* A plain file. This needs a closer look.*/
  376.       xfh = xOpen( glob, lock->xlock, fib->fib_FileName, MODE_OLDFILE );
  377.       if( !xfh ){
  378.          debug(("Error: ModifyFIB(): Couldn't open file: %ld\n",glob->ioerr));
  379.          return DOSFALSE;
  380.       }
  381.       filetype = xFileType( glob, xfh );
  382.       err = ModifyFIB_type( glob, filetype, lock, fib, xfh );
  383.       if( !err ) saveioerr = glob->ioerr;
  384.       xClose(glob, xfh);
  385.       if( !err ) glob->ioerr = saveioerr;
  386.       return err;
  387.    }else{
  388.       /* Do nothing for a directory.*/
  389.       return DOSTRUE;
  390.    }
  391. }
  392.  
  393. /* XObjModifyFIB() is just a NO-OP.*/
  394. BOOL XObjModifyFIB( glb glob, struct CFSLock *lock,struct FileInfoBlock *fib, struct FileHandle *xfh ){
  395.    return DOSTRUE;
  396. }
  397.  
  398.  
  399. struct CFSLock *XObjCreateDir( glb glob, struct CFSLock *parentlock, char *name ){
  400.    struct CFSLock *newlock;
  401.    struct FileLock *xlock;
  402.    
  403.    if( !(xlock = xCreateDir(glob, parentlock->xlock, name)) ){
  404.       return 0L;
  405.    }
  406.    newlock = XObjMakeLock( glob, xlock, xlock->fl_Access );
  407.    if( !newlock ){
  408.       LONG saveioerr = glob->ioerr;
  409.  
  410.       /* Oh No! We're left with a dangling directory...
  411.        * Try to remove it before returning.
  412.        */
  413.       debug(("XObjCreateDir(): Trying to delete dangling directory..."));
  414.       xUnLock(glob, xlock);
  415.       if( CFSDeleteFile( glob, parentlock, name ) )
  416.          debug(("Succes!\n"));
  417.       else
  418.          debug(("Failure...\n"));
  419.       glob->ioerr = saveioerr;
  420.    }
  421.    return newlock;
  422. }
  423.  
  424.  
  425. BOOL XObjSetProtection(glb glob, struct CFSLock *parent, char *name, LONG mask){
  426.    BOOL err;
  427.    
  428.    err = xSetProtection(glob, parent->xlock, name, mask);
  429.    return err;
  430. }
  431.  
  432. BOOL XObjSetComment(glb glob, struct CFSLock *parent, char *name, char *comment)
  433.  
  434. {
  435.  BOOL Success;
  436.    
  437.  if (Success=xSetComment(glob,parent->xlock,name,comment))
  438.   xScan (glob,parent->xlock,name);
  439.  
  440.  return Success;
  441. }
  442.  
  443. BOOL XObjSetFileDate(glb glob,struct CFSLock *parent,char *name,struct DateStamp *ds)
  444.  
  445. {
  446.  BOOL Success;
  447.    
  448.  if (Success=xSetFileDate(glob,parent->xlock,name,ds))
  449.   xScan (glob,parent->xlock,name);
  450.  
  451.  return Success;
  452. }
  453.  
  454.  
  455. BOOL XObjDeleteFile(glb glob, struct CFSLock *parent, char *name){
  456.    BOOL err;
  457.    
  458.    err = xDeleteFile(glob, parent->xlock, name);
  459.    return err;
  460. }
  461.  
  462.  
  463. BOOL XObjRename(glb glob, struct CFSLock *p1, char *n1, struct CFSLock *p2, char *n2){
  464.    BOOL err;
  465.    
  466.    if(p2->objtype != XOBJECT){
  467.       debug(("XObjRename(): Error: rename to lock of type %ld\n",p2->objtype));
  468.       glob->ioerr = ERROR_RENAME_ACROSS_DEVICES;
  469.       return DOSFALSE;
  470.    }else{
  471.       err = xRename(glob, p1->xlock, n1, p2->xlock, n2);
  472.       return err;
  473.    }
  474. }
  475.  
  476.  
  477. /* End of xobj.c */
  478.